package com.example.pan.stream.core;

import java.util.Map;

/**
 * @Author: invictusQAQ
 * @Date: 2023-12-13-17:29
 * @Description: 消息发送者顶级接口
 */
public interface IStreamProducer {
    /**
     * 发送消息
     * @param channelName
     * @param deploy
     * @return
     */
    boolean sendMessage(String channelName, Object deploy);

    boolean sendMessage(String channelName, Object deploy, Map<String, Object> headers);
}
